/*    *//*
 package com.gillion.grule.client.logger.utils;
*/
/*    *//*

*/
/*    *//*
 import com.gillion.grule.client.logger.KafkaExecutorLogger;
*/
/*    *//*
 import com.google.common.collect.Maps;
*/
/*    *//*
 import java.util.HashMap;
*/
/*    *//*
 import org.apache.commons.lang3.StringUtils;
*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*

*/
/*    *//*
 public class KafkaLoggerFactory
*/
/*    *//*
 {
*/
/* 20 *//*
   private static HashMap<String, KafkaExecutorLogger> loggers = Maps.newHashMap();
*/
/*    *//*

*/
/*    *//*
   public static KafkaExecutorLogger getInstance(String topic) {
*/
/* 23 *//*
     if (loggers.isEmpty()) {
*/
/* 24 *//*
       initLogger(topic);
*/
/*    *//*
     }
*/
/* 26 *//*
     if (!loggers.containsKey(topic)) {
*/
/* 27 *//*
       throw new RuntimeException("topic is not exist:".concat(topic));
*/
/*    *//*
     }
*/
/* 29 *//*
     return loggers.get(topic);
*/
/*    *//*
   }
*/
/*    *//*

*/
/*    *//*
   public static void initLogger(String topic) {
*/
/* 33 *//*
     if (StringUtils.isEmpty(topic)) {
*/
/* 34 *//*
       throw new RuntimeException("topic is empty");
*/
/*    *//*
     }
*/
/* 36 *//*
     KafkaExecutorLogger logger = new KafkaExecutorLogger();
*/
/* 37 *//*
     logger.setKafkaProducer(KafkaProducerFactory.getInstance(topic));
*/
/* 38 *//*
     logger.setLogTopic(topic);
*/
/* 39 *//*
     loggers.put(topic, logger);
*/
/*    *//*
   }
*/
/*    *//*
 }


*/
/* Location:              D:\apache-tomcat-9.0.76\webapps\grule-manager\WEB-INF\lib\grule-client-2.0.2.RELEASE.jar!\com\gillion\grule\client\logge\\utils\KafkaLoggerFactory.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */
